#ifndef PLAYER_MSG_QUEUE_H
#define PLAYER_MSG_QUEUE_H

#include "common.h"
#include "msg_q.h"

typedef struct
{
	int type;
	int err;
	int bufferId;
	int generation;
	int notifyComplete;
	int needNotify;
	int seekTime;
	int size;
	unsigned char* buffer;
}Msg_T;

enum{
	ShutDownOwn,
	SetDataSource
};
class MsgQueue
{
public:
	MsgQueue();
	~MsgQueue();
	status_t SendMessage(Msg_T *msg);
	void ReceiveMessage(Msg_T *msg);
private:
	HANDLE_T mHandle;
};
#endif